package cn.xiaochao.zebra;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import cn.xiaochao.file.FileCollector;
import cn.xiaochao.file.FileToBlock;
import cn.xiaochao.zk.ZKConnectRunner;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
        System.out.println( "jobtracker!" );
        ExecutorService es = Executors.newCachedThreadPool();
        //1.加载日志扫描进程
        es.submit(new FileCollector());
        //2.加载日志切块的线程
        es.submit(new FileToBlock());
        
        //启动切片分发
        es.submit(new ZKConnectRunner());
        
        
        
        
        

        
        
    }
}
